package com.ruoyi.yanjing.service;


import com.ruoyi.yanjing.domain.ElectricityPole;
import com.ruoyi.yanjing.domain.req.PointMessageToTopicReq;
import com.ruoyi.yanjing.domain.req.QueryMessageByTopicReq;

/**
 * 动态添加订阅的主题
 */
public interface MqttService {

    /**
     * 添加主题
     */
    String addTopic(ElectricityPole electricityPole);

    String addTopic(String topic );


    /**
     * 下发配置到主题
     * @param req
     * @return
     */
    String addMessageToTopic(PointMessageToTopicReq req);


    /**
     * 查询配置
     * @param req
     * @return
     */
    String addQueryMessageToTopic(QueryMessageByTopicReq req);
}
